package com.example3.demo.rocketmq.message.imp;

import com.example3.demo.entity.User;
import com.example3.demo.rocketmq.message.MessageProcessor;
import org.springframework.stereotype.Service;

/**
 * @author:
 * @Date: 19:26 2019/1/15
 */
@Service
public class UserProcessorImpl implements MessageProcessor<User> {

    @Override
    public boolean handleMessage(User user) {
        System.out.println("user receive : " + user.toString());
        return true;
    }

    @Override
    public Class<User> getClazz() {
        return User.class;
    }
}
